package com.sjk.flink.relevance;

import com.fasterxml.jackson.databind.JsonNode;
import com.sjk.flink.util.ObjectMapperUtil;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisCluster;

/**
 * 关联性检查测试
 *
 */
public class TestRelevanceValidator implements  RelevanceValidator{
    @Override
    public boolean doCheck(Jedis jedis, String json) {
        try {
            JsonNode jsonNode = ObjectMapperUtil.getObjectMapper().readTree(json);
            //todo 你的业务

        } catch (Exception ex){

        }
        return false;
    }
}
